package com.example.demo.common;

import com.example.demo.mqsever.core.BasicProperties;

import java.io.IOException;

@FunctionalInterface
public interface Consumer {
    // 在每次服务器收到消息之后, 来调用.
    // 通过这个方法把消息推送给对应的消费者.
    void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws MqException, IOException;
}
